package com.lzq.mq.broker.model;

import lombok.Data;

import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong;

/**
 * commitLog文件模型
 */
@Data
public class CommitLogModel {

    /**
     * 文件名
     */
    private String fileName;
    /**
     * 最新的偏移量
     */
    private AtomicInteger offset;
    /**
     * 最大的偏移上限(即文件大小上限)
     */
    private Long offsetLimit;

    public long countDiff() {
        return offsetLimit - offset.get();
    }
}
